const mysql = require('mysql')
const { MYSQL_CONFIG } = require('../config/db')

// 创建链接对象
const connection = mysql.createConnection(MYSQL_CONFIG)

// 开始链接
connection.connect()

// 统一执行sql的函数
function exec(sql) {
	return new Promise((resolve, reject) => {
		connection.query(sql, (err, result) => {
			if (err) {
				reject(err)
				return
			}
			resolve(result)
		})
	})
}

module.exports = {
	exec
}